package com.kafka.service;

import com.kafka.config.KafkaProducer;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

@Service
@RequiredArgsConstructor
public class KafkaTest {
    private final KafkaProducer kafkaProducer;

    public Boolean sendMsg(String msg){
        kafkaProducer.sendMessage(msg);
        return true;
    }
}
